home *** CD-ROM | disk | FTP | other *** search
/ Language/OS - Multiplatform Resource Library / LANGUAGE OS.iso / cpp_libs / rjs.lha / RJS / NDR / src / NDR_send.C < prev    next >
Encoding:
C/C++ Source or Header  |  1991-06-14  |  3.4 KB  |  148 lines
  1. #include <string.h>
  2. #include <sys/types.h>
  3. #include <sys/uio.h>
  4. #include "NDR.h"
  5.  
  6. extern "C" {
  7.     unsigned short htons(unsigned short);
  8. };
  9.  
  10.  
  11. RJS_Transport &operator<<(RJS_Transport &tr, RJS_NDR_send &ndr)
  12. {
  13.     unsigned short len=htons(ndr.raw_length());
  14.     struct iovec iov[2];
  15.     iov[0].iov_base = (char *) &len;
  16.     iov[0].iov_len  = sizeof(unsigned short);
  17.     iov[1].iov_base = ndr.raw_data();
  18.     iov[1].iov_len  = ndr.raw_length();
  19.     tr.writev(iov,2);
  20.     return tr;
  21. }
  22.  
  23. ostream &operator<<(ostream &os, RJS_NDR_send &ndr)
  24. {
  25.     cout << "local_endian() => " << ndr.local_endian() << endl;
  26.     cout << "local_character() => " << ndr.local_character() << endl;
  27.     cout << "local_floating() => " << ndr.local_floating() << endl;
  28.     cout << "raw_length() => " << ndr.raw_length() << endl;
  29.     for (int i=0; i< ndr.raw_length(); i++) {
  30.         cout << i << "\t" << int(*(ndr.raw_data()+i)) << endl;
  31.     }
  32.     return os;
  33. }
  34.  
  35. RJS_NDR_send &operator<<(RJS_NDR_send &ndr, RJS_XNDR &x) {
  36.     x.to_external(ndr);
  37.     return ndr;
  38. }
  39.  
  40. RJS_NDR_send::RJS_NDR_send()
  41. { 
  42.     start_data=NULL; 
  43.     end_data=NULL; 
  44.     end_alloc=NULL; 
  45. }
  46.  
  47.  
  48. void RJS_NDR_send::reset()
  49. {
  50.     end_data = start_data+2;
  51. }
  52.  
  53. void RJS_NDR_send::init(char *buffer, int size)
  54. {
  55.     int align=((unsigned int)(buffer)) % sizeof(double);
  56.     if (align) buffer += (sizeof(double)-align);    
  57.     start_data  = buffer;
  58.     end_data    = buffer;
  59.     end_alloc   = buffer+size;
  60.     (*end_data++)   = (local_endian() << 4)  | (local_character());
  61.     (*end_data++)   =  (local_floating());
  62.  
  63. }
  64.  
  65. RJS_NDR_send &RJS_NDR_send::insert(char *d, int count)
  66. {
  67.     (*this) << count;
  68.     strncpy(end_data,d,count);
  69.     end_data += count;
  70.     return *this;
  71. }
  72.  
  73.  
  74. RJS_NDR_send &operator<<(RJS_NDR_send &ndr,char ch)
  75. {
  76.     *ndr.end_data++ = ch;
  77.     return ndr;
  78. }
  79.  
  80. RJS_NDR_send &operator<<(RJS_NDR_send &ndr,unsigned char ch)
  81. {
  82.     *ndr.end_data++ = ch;
  83.     return ndr;
  84. }
  85.  
  86. RJS_NDR_send &operator<<(RJS_NDR_send &ndr,short i)
  87. {
  88.     if (((unsigned int)(ndr.end_data)) % sizeof(short)) ndr.end_data++; 
  89.     * (short *) ndr.end_data = i;
  90.     ndr.end_data += sizeof(short);
  91.     return ndr;
  92. }
  93.  
  94. RJS_NDR_send &operator<<(RJS_NDR_send &ndr,unsigned short i)
  95. {
  96.     if (((unsigned int)(ndr.end_data)) % sizeof(unsigned short)) ndr.end_data++;
  97.     * (unsigned short *) ndr.end_data = i;
  98.     ndr.end_data += sizeof(unsigned short);
  99.     return ndr;
  100. }
  101.  
  102. RJS_NDR_send &operator<<(RJS_NDR_send &ndr,int i)
  103. {
  104.     int align=((unsigned int)(ndr.end_data)) % sizeof(int);
  105.     if (align) ndr.end_data += (sizeof(int)-align); // align on natural
  106.     * (int *) ndr.end_data = i;
  107.     ndr.end_data += sizeof(int);
  108.     return ndr;
  109. }
  110.  
  111. RJS_NDR_send &operator<<(RJS_NDR_send &ndr,unsigned int i)
  112. {
  113.     int align=((unsigned int)(ndr.end_data)) % sizeof(unsigned int);
  114.     if (align) ndr.end_data += (sizeof(unsigned int)-align);
  115.     * (unsigned int *) ndr.end_data = i;
  116.     ndr.end_data += sizeof(unsigned int);
  117.     return ndr;
  118. }
  119.  
  120. RJS_NDR_send &operator<<(RJS_NDR_send &ndr,float d)
  121. {
  122.     int align=((unsigned int)(ndr.end_data)) % sizeof(float);
  123.     if (align) ndr.end_data += (sizeof(float)-align);
  124.     * (float *) ndr.end_data = d;
  125.     ndr.end_data += sizeof(float);
  126.     return ndr;
  127. }
  128.  
  129. RJS_NDR_send &operator<<(RJS_NDR_send &ndr,double d)
  130. {
  131.     int align=((unsigned int)(ndr.end_data)) % sizeof(double);
  132.     if (align) ndr.end_data += (sizeof(double)-align);
  133.     * (double *) ndr.end_data = d;
  134.     ndr.end_data += sizeof(double);
  135.     return ndr;
  136. }
  137.  
  138. RJS_NDR_send &operator<<(RJS_NDR_send &ndr,const char *str)
  139. {
  140.     unsigned short len=strlen(str)+1;
  141.     ndr << len;
  142.     strcpy(ndr.end_data,str);
  143.     ndr.end_data += len;
  144.     return ndr;
  145. }
  146.  
  147.  
  148.